package co.edu.uniandes.bi.etl.audi.Helpers;

import java.sql.ResultSet;
import java.sql.SQLException;

import co.edu.uniandes.bi.db.TweetsDAO;

public class UsuariosDB {

	private TweetsDAO tweetsDAO;

	public UsuariosDB()
	{
		tweetsDAO = TweetsDAO.getInstance();
		
	}
	public void insertarUsuario(String nombreUsuario)
	{
		boolean verificarPais=verificarSiExiste(nombreUsuario);
		if(!verificarPais)
		{
			String sentencia="insert into usuariosrs ( nombreusuariors , apellidousuariors , edad , sexo )values('"+nombreUsuario.replace("'", "")+"', 'perez',25,'M');";
			tweetsDAO.ejecutarSQL(sentencia);
		}
	}
	
	private  boolean verificarSiExiste(String nombreUsuario)
	{
		String query="SELECT * FROM usuariosrs where nombreusuariors = '" + nombreUsuario.replace("'", "") + "'";
		ResultSet resultSet=tweetsDAO.hacerConsulta(query);
		if(resultSet==null)
		{
			return false;
		}else
		{
			try {
				if(!resultSet.next())
				{
					return false;
				}else
				{
					return true;
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		return false;
	}
	/**
	 * 
	 * @param tweet
	 * @return
	 */
	public int darLlaveSurrogada(String nombreUsuario)
	{
		String query="SELECT * FROM usuariosrs where nombreusuariors = '" + nombreUsuario.replace("'", "") + "'";
		ResultSet resultSet=tweetsDAO.hacerConsulta(query);
		try {
			while(resultSet.next())
			{
				int id=resultSet.getInt("llaveusuariors");
				System.out.println(id);
				return id;
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return-1;
	}
	/**
	 * @param args
	 */
	public static void main(String[] args) {
		String usuario= "Maria";
		UsuariosDB usuariosDB=new UsuariosDB();
		usuariosDB.insertarUsuario(usuario);
		usuariosDB.darLlaveSurrogada(usuario);
	}
}
